package com.wo56.pushmsgcenter.business.redis;

import java.util.Map;
import java.util.concurrent.Callable;

import com.framework.core.SysContexts;
import com.wo56.pushmsgcenter.business.consumer.interfaces.IConsumeMsg;

public class ConsumeMsgCallable implements Callable<Map> {
	public String channel;
	public String message;
	public ConsumeMsgCallable(String channel, String message) {
		this.channel = channel;
		this.message = message;
	}
	@Override
	public Map call() throws Exception {
		//转换消息 调用通用类处理消息
		IConsumeMsg intf = (IConsumeMsg)SysContexts.getBean("consumeMsgImpl");
		intf.consumeMsg(null);
		return null;
	}

}
